// #ifndef ADAPTER_MQTT_ADAPTER_H_
// #define ADAPTER_MQTT_ADAPTER_H_
// #include "adapter_manager.h"
// #include "util/util.h"
// #include "mosquitto.h"

// class MQTTAdapter{
//     public:
//         bool InitSubscriber(std::shared_ptr<Adapter<struct mosquitto,struct mosquitto_message>>& adapter,const std::string& channel, int queue_size = 1) {
//             adapter->subscriber_ = Instance()->node_handle_->subscribe(
//                 channel, &LcmAdapter<InputMessageType>::LCMCallback, adapter.get());
//     return true;
//   }

// };

// #endif